package com.cmdfut.rxjava.rxjava;

/**
 * @ClassName: AbstractObservableWithUpstream
 * @Description:
 * @Author: greenlee
 * @Date: 2020/6/11 10:29
 */
abstract class AbstractObservableWithUpstream<T,U> extends Observable<U> {

    protected final ObservableSource<T> source;

    public AbstractObservableWithUpstream(ObservableSource<T> source) {
        this.source = source;
    }
}
